# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms_dm_todo.dim.dim_frm_network_info_desc import jms_dim__dim_frm_network_info_desc

jms_oracle__dim_frm_network_info_desc = BashOperator(
    task_id='jms_oracle__dim_frm_network_info_desc',
    execution_timeout=timedelta(hours=1),
    email=['jokic.wang@jtexpress.com', 'yl_bigdata@yl-scm.com'],
    # name='jms_oracle__dim_frm_network_info_desc_{{ execution_date | date_add(1) | cst_ds }}',
    bash_command="jms_dm_todo/oracle/dim_frm_network_info_desc/execute.sh",
    pool='spmi_apack',
    retries=1,
    pool_slots=2,
)

jms_oracle__dim_frm_network_info_desc << [jms_dim__dim_frm_network_info_desc]
